package com.xzh.seckill.config;



import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

//@Configuration
public class RabbitMQfanoutConfig {
    public static final String QUEUE01 = "queue_fanout01";
    public static final String QUEUE02 = "queue_fanout02";
    public static final String EXCHANGE = "fanoutExchange";
   // @Bean
    public Queue queue()
    {
        //第一个参数：队列名字，第二参数：是否开启持久化
        return new Queue("queue",true);
    }

    //@Bean
    public Queue queue01()
    {
        return new Queue(QUEUE01);
    }
   // @Bean
    public Queue queue02()
    {
        return new Queue(QUEUE02);
    }
    //@Bean
    public FanoutExchange fanoutExchange()
    {
        return new FanoutExchange(EXCHANGE);
    }
   // @Bean
    public Binding binding01()
    {
        return BindingBuilder.bind(queue01()).to(fanoutExchange());
    }
   // @Bean
    public Binding binding02()
    {
        return BindingBuilder.bind(queue02()).to(fanoutExchange());
    }
}
